<?php
//
//    ______         ______           __         __         ______
//   /\  ___\       /\  ___\         /\_\       /\_\       /\  __ \
//   \/\  __\       \/\ \____        \/\_\      \/\_\      \/\ \_\ \
//    \/\_____\      \/\_____\     /\_\/\_\      \/\_\      \/\_\ \_\
//     \/_____/       \/_____/     \/__\/_/       \/_/       \/_/ /_/
//
//   上海商创网络科技有限公司
//
//  ---------------------------------------------------------------------------------
//
//   一、协议的许可和权利
//
//    1. 您可以在完全遵守本协议的基础上，将本软件应用于商业用途；
//    2. 您可以在协议规定的约束和限制范围内修改本产品源代码或界面风格以适应您的要求；
//    3. 您拥有使用本产品中的全部内容资料、商品信息及其他信息的所有权，并独立承担与其内容相关的
//       法律义务；
//    4. 获得商业授权之后，您可以将本软件应用于商业用途，自授权时刻起，在技术支持期限内拥有通过
//       指定的方式获得指定范围内的技术支持服务；
//
//   二、协议的约束和限制
//
//    1. 未获商业授权之前，禁止将本软件用于商业用途（包括但不限于企业法人经营的产品、经营性产品
//       以及以盈利为目的或实现盈利产品）；
//    2. 未获商业授权之前，禁止在本产品的整体或在任何部分基础上发展任何派生版本、修改版本或第三
//       方版本用于重新开发；
//    3. 如果您未能遵守本协议的条款，您的授权将被终止，所被许可的权利将被收回并承担相应法律责任；
//
//   三、有限担保和免责声明
//
//    1. 本软件及所附带的文件是作为不提供任何明确的或隐含的赔偿或担保的形式提供的；
//    2. 用户出于自愿而使用本软件，您必须了解使用本软件的风险，在尚未获得商业授权之前，我们不承
//       诺提供任何形式的技术支持、使用担保，也不承担任何因使用本软件而产生问题的相关责任；
//    3. 上海商创网络科技有限公司不对使用本产品构建的商城中的内容信息承担责任，但在不侵犯用户隐
//       私信息的前提下，保留以任何方式获取用户信息及商品信息的权利；
//
//   有关本产品最终用户授权协议、商业授权与技术服务的详细内容，均由上海商创网络科技有限公司独家
//   提供。上海商创网络科技有限公司拥有在不事先通知的情况下，修改授权协议的权力，修改后的协议对
//   改变之日起的新授权用户生效。电子文本形式的授权协议如同双方书面签署的协议一样，具有完全的和
//   等同的法律效力。您一旦开始修改、安装或使用本产品，即被视为完全理解并接受本协议的各项条款，
//   在享有上述条款授予的权力的同时，受到相关的约束和限制。协议许可范围以外的行为，将直接违反本
//   授权协议并构成侵权，我们有权随时终止授权，责令停止损害，并保留追究相关责任的权力。
//
//  ---------------------------------------------------------------------------------
//
use Ecjia\System\Notifications\ExpressFinished;
defined('IN_ECJIA') or exit('No permission resources.');


/**
 * 配送完成
 * @author zrl
 */
class express_finished_module extends api_admin implements api_interface {
    public function handleRequest(\Royalcms\Component\HttpKernel\Request $request) {	
    	$this->authadminSession();
    	if ($_SESSION['staff_id'] <= 0) {
            return new ecjia_error(100, 'Invalid session');
        }
		
        $express_id = $this->requestData('express_id', 0);
        
		if (empty($express_id)) {
    		return new ecjia_error('invalid_parameter', RC_Lang::get ('system::system.invalid_parameter' ));
    	}
    	
    	$field = 'eo.*, oi.add_time as order_time, oi.pay_time,  oi.order_status, oi.pay_status, oi.expect_shipping_time, oi.order_amount, oi.pay_name, sf.merchants_name, sf.district as sf_district, sf.street as sf_street, sf.address as merchant_address, sf.longitude as sf_longitude, sf.latitude as sf_latitude';
		$dbview = RC_DB::table('express_order as eo')
			->leftJoin('store_franchisee as sf', RC_DB::raw('sf.store_id'), '=', RC_DB::raw('eo.store_id'))
			->leftJoin('order_info as oi', RC_DB::raw('eo.order_id'), '=', RC_DB::raw('oi.order_id'));
		$express_order_info	= $dbview->where(RC_DB::raw('eo.express_id'), $express_id)->select(RC_DB::raw('eo.*'), RC_DB::raw('oi.add_time as order_time'), RC_DB::raw('oi.pay_time'), RC_DB::raw('oi.order_status'), RC_DB::raw('oi.pay_status'), RC_DB::raw('oi.expect_shipping_time'), RC_DB::raw('oi.order_amount'), RC_DB::raw('oi.pay_name'), RC_DB::raw('sf.merchants_name'), RC_DB::raw('sf.district as sf_district'), RC_DB::raw('sf.street as sf_street'), RC_DB::raw('sf.address as merchant_address'), RC_DB::raw('sf.longitude as sf_longitude'), RC_DB::raw('sf.latitude as sf_latitude'))->first();
		$data = array(
				'order_status' 		=> OS_CONFIRMED,
				'shipping_status'	=> SS_RECEIVED,
				'pay_status'		=> PS_PAYED
		);
		
		/*检查订单和配送单状态*/
		if ($express_order_info['status'] == '5' || $express_order_info['order_status'] == OS_CONFIRMED || $express_order_info['shipping_status'] == SS_RECEIVED) {
			return new ecjia_error('express_order_finished', '此配送单已配送完成了！');
		}
		
		$update = RC_DB::table('order_info')->where('order_id', $express_order_info['order_id'])->update($data);
		
		//订单分成
		RC_Api::api('commission', 'add_bill_queue', array('order_type' => 'buy', 'order_id' => $express_order_info['order_id']));
		RC_Api::api('goods', 'update_goods_sales', array('order_id' => $express_order_info['order_id']));
		
		
// 		if ($update) {
			$db_order_status_log = RC_DB::table('order_status_log');
							   
			$order_status_data = array(
					'order_status' => RC_Lang::get('orders::order.confirm_receipted'),
					'order_id' 	   => $express_order_info['order_id'],
					'message'	   => '宝贝已签收，购物愉快！',
					'add_time'	   => RC_Time::gmtime()
			);
			$db_order_status_log->insert($order_status_data);
			 
			 
			$order_status_data = array(
					'order_status' => RC_Lang::get('orders::order.order_finished'),
					'order_id' 	   => $express_order_info['order_id'],
					'message'	   => '感谢您在'.ecjia::config('shop_name').'购物，欢迎您再次光临！',
					'add_time'	   => RC_Time::gmtime()
			);
			$db_order_status_log->insert($order_status_data);
			
			/* 记录日志 */
			RC_Loader::load_app_func('admin_order', 'orders');
			order_action($express_order_info['order_sn'], OS_CONFIRMED, SS_RECEIVED, PS_PAYED, '', '买家');
			
			if ($express_order_info['status'] != 5) {
				$orm_staff_user_db = RC_Model::model('express/orm_staff_user_model');
				$user = $orm_staff_user_db->find($express_order_info['staff_id']);
				
				//短信发送
				if (!empty($express_order_info['express_mobile'])) {
					$options = array(
							'mobile' => $express_order_info['express_mobile'],
							'event'	 => 'sms_express_confirm',
							'value'  =>array(
									'express_sn'   => $express_order_info['express_sn'],
									'service_phone'=> ecjia::config('service_phone'),
							),
					);
					RC_Api::api('sms', 'send_event_sms', $options);
				}
				
				//推送消息
				$options = array(
						'user_id'   => $express_order_info['staff_id'],
						'user_type' => 'merchant',
						'event'     => 'express_confirm',
						'value' => array(
								'express_sn'    => $express_order_info['express_sn'],
								'service_phone' => ecjia::config('service_phone'),
						),
						'field' => array(
								'open_type' => 'admin_message',
						),
				);
				RC_Api::api('push', 'push_event_send', $options);
				
				//消息通知
				$express_from_address = ecjia_region::getRegionName($express_order_info['sf_district']).ecjia_region::getRegionName($express_order_info['sf_street']).$express_order_info['merchant_address'];
				$express_to_address = ecjia_region::getRegionName($express_order_info['district']).ecjia_region::getRegionName($express_order_info['street']).$express_order_info['address'];
					
				$express_data = array(
						'title'     => '配送成功',
						'body'      => '买家已成功确认收货！配送单号为：'.$express_order_info['express_sn'],
						'data'      => array(
								'express_id'            => $express_order_info['express_id'],
								'express_sn'         	=> $express_order_info['express_sn'],
								'express_type'  		=> $express_order_info['from'],
								'label_express_type'    => $express_order_info['from'] == 'assign' ? '系统派单' : '抢单',
								'order_sn'           	=> $express_order_info['order_sn'],
								'payment_name'        	=> $express_order_info['pay_name'],
								'express_from_address'  => '【'.$express_order_info['merchants_name'].'】'. $express_from_address,
								'express_from_location' => array(
										'longitude' => $express_order_info['merchant_longitude'],
										'latitude'  => $express_order_info['merchant_latitude'],
								),
								'express_to_address'    => $express_to_address,
								'express_to_location'   => array(
										'longitude' 		=> $express_order_info['longitude'],
										'latitude'  		=> $express_order_info['latitude'],
								),
								'distance'        	=> $express_order_info['distance'],
								'consignee'       	=> $express_order_info['consignee'],
								'mobile'          	=> $express_order_info['mobile'],
								'order_time'      	=> RC_Time::local_date(ecjia::config('time_format'), $express_order_info['add_time']),
								'pay_time'       	=> empty($express_order_info['pay_time']) 	? '' : RC_Time::local_date(ecjia::config('time_format'), $express_order_info['pay_time']),
								'best_time'       	=> empty($express_order_info['best_time']) 	? '' : RC_Time::local_date(ecjia::config('time_format'), $express_order_info['best_time']),
								'shipping_fee'    	=> $express_order_info['commision'],
								'order_amount'    	=> $express_order_info['order_amount'],
						),
				);
				$express_finished = new ExpressFinished($express_data);
				RC_Notification::send($user, $express_finished);
				
				$update_data = array(
						'status' 			=> 5,
						'signed_time' 		=> RC_Time::gmtime(),
						'commision_status'	=> 1,
						'commision_time'	=> RC_Time::gmtime(),
				);
				 
				RC_DB::table('express_order')->where('express_id', $express_order_info['express_id'])->update($update_data);
				 
				/*用户确认收货后更新配送员资金账户信息*/
				RC_Loader::load_app_class('express_account_change', 'express', false);
				 
				$options = array(
						'staff_user_id' => $express_order_info['staff_id'],
						'user_money'	=> $express_order_info['commision'],
						'frozen_money'	=> '0.00',
						'change_desc'	=> '配送订单'.$express_order_info['order_sn'].'所得的配送费用',
						'change_type'	=> '99'
				);
				 
				express_account_change::express_account_change_log($options);
				 
				/*当订单配送方式为o2o速递时,记录o2o速递物流信息*/
				if ($express_order_info['shipping_id'] > 0) {
					$shipping_info = ecjia_shipping::pluginData($express_order_info['shipping_id']);
					if ($shipping_info['shipping_code'] == 'ship_o2o_express' || $shipping_info['shipping_code'] == 'ship_ecjia_express') {
						$data = array(
								'express_code' => $shipping_info['shipping_code'],
								'track_number' => $express_order_info['invoice_no'],
								'time'		   => RC_Time::local_date(ecjia::config('time_format'), RC_Time::gmtime()),
								'context'	   => '买家已成功确认收货！',
						);
						RC_DB::table('express_track_record')->insert($data);
					}
				}
				 
				/* 更新配送员相关信息*/
				$express_user = RC_DB::table('express_user')->where('user_id', $express_order_info['staff_id'])->first();
				if ($express_user) {
					RC_DB::table('express_user')->where('user_id', $express_order_info['staff_id'])->increment('delivery_count', 1);
					RC_DB::table('express_user')->where('user_id', $express_order_info['staff_id'])->increment('delivery_distance', $express_order_info['distance']);
					RC_DB::table('express_user')->where('user_id', $express_order_info['staff_id'])->update(array('longitude' => $express_order_info['longitude'], 'latitude' => $express_order_info['latitude']));
				} else {
					RC_DB::table('express_user')->insert(array('user_id' => $express_order_info['staff_id'], 'store_id' => $_SESSION['store_id'], 'delivery_count' => 1, 'delivery_distance' => $express_order_info['distance'], 'longitude' => $express_order_info['longitude'], 'latitude' => $express_order_info['latitude']));
				}
			}
// 		}
		
		return array();
	 }	
}

// end